import os

from celery.app.base import Celery
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "meiduo_mall.settings.dev")

#创建celery应用,参数１为自定义的名字
celery_app = Celery("meiduo123", broker='redis://127.0.0.1:6379/15', backend='redis://127.0.0.1:6379/14')
# celery_app = Celery('meiduo',
#                     broker='redis://127.0.0.1:6379/15',
#                     # 后台: 用来保存任务执行后的返回值
#                     backend='redis://127.0.0.1:6379/14')

#指定扫描文件位置,关键是必须存在tasks文件，主要扫描该文件

celery_app.autodiscover_tasks(['celery_tasks.sms', 'celery_tasks.email', 'celery_tasks.html'])
